package com.nwpu.bigdata.dao;

import java.util.Map;

import org.influxdb.InfluxDB;
import org.influxdb.dto.QueryResult;

public interface InfluxdbDao {

	void createDatabase();

	/**
	 *  建保存策略
	 * @param duration 存放时间
	 * @param replicationNum　备份数量
	 */
	void createRetentionPolicy(String duration, Integer replicationNum);

	QueryResult query(String cmd);

	/**
	 * 插入数据
	 * @param measurement　表名
	 * @param tags
	 * @param fields
	 */
	void insert(String measurement, Map<String, String> tags, Map<String, Object> fields);

	String getDatabase();

	String getPolicyName();

	InfluxDB getInfluxDB();

	void setDatabase(String database);

	void setPolicyName(String policyName);

}